package com.junray.mqttmanager

import kotlinx.coroutines.flow.MutableStateFlow
import kotlinx.coroutines.flow.asStateFlow

object ArrivedMsgFlow {

    private val _msg = MutableStateFlow<ArrivedMessage?>(null)
    val msg = _msg.asStateFlow()
    fun send(msg: ArrivedMessage?){
        _msg.value = msg
    }

}